package com.lzy.demo;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * 生产者
 * @ClassName QueueProducer
 * @Author liu zhiyong
 * @Date 2020/8/13 9:24
 * @Version 1.0
 */
public class QueueProducer {

    public static void main(String[] args) throws JMSException {
        //1.创建连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.128:61616");
        //2.获取连接
        Connection connection = connectionFactory.createConnection();
        //3.启动连接
        connection.start();
        //4.获取session(参数1：是否启动事务,参数2：消息确认模式)
        /*
        第1个参数 是否使用事务
        第2个参数 消息的确认模式
	    AUTO_ACKNOWLEDGE = 1    自动确认
	    CLIENT_ACKNOWLEDGE = 2    客户端手动确认
	    DUPS_OK_ACKNOWLEDGE = 3    自动批量确认
	    SESSION_TRANSACTED = 0    事务提交并确认
        */
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5.创建队列对象
        Queue queue = session.createQueue("test-queue");
        //6.创建消息生产者
        MessageProducer producer = session.createProducer(queue);
        //7.创建消息
        TextMessage textMessage = session.createTextMessage("activeMQ测试10");
        //8.发送消息
        producer.send(textMessage);
        //9.关闭资源
        producer.close();
        session.close();
        connection.close();

    }
}
